//
// Created by jinbang.li on 2023/4/6.
//

#include "IOpDemux.h"
#include "../Log/OpLog.h"
void IOpDemux::Main() {
//    for (;;){
//        OpData opData = Read();
//        if(opData.size <= 0) break;
//    }
    /**
     * 通过改造通过变量控制开启或关闭
     */
    while (!isExit){
        OpData data = Read();
        if (data.size > 0) notify(data);
   }

}